package com.wuad.platformwuad.component.rabbitMq1;

import com.wuad.platformwuad.common.Result;
import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

/**
 * RabbitMQ测试消息发送和消息接受
 *
 * @author wuaodi
 */
@Slf4j
@RequestMapping("/testSendMsg")
@RestController
public class SendMsgToRabbit {

//    /**
//     * 使用RabbitTemplate,这提供了接收/发送等等方法
//     */
//    @Resource
//    RabbitTemplate rabbitTemplate;
//
//    @RequestMapping("/sendDirectMessage")
//    public Result sendDirectMessage() {
//        String messageId = String.valueOf(UUID.randomUUID());
//        String messageData = "test message, hello!";
//        String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
//        Map<String,Object> map=new HashMap<>();
//        map.put("messageId",messageId);
//        map.put("messageData",messageData);
//        map.put("createTime",createTime);
//        log.info("消息生产者：{}", map);
//        rabbitTemplate.convertAndSend("TestDirectExchange","TestDirectQueue",map);
//
//        return Result.success(200, map);
//    }



}
